package com.cnpc.bds.sdk.sink.kafka.handler;

public interface Handler<I, O> {

    O handle(I msg);

    Handler next();

    Handler prev();

}
